'''PySpark入门'''
# 导包
from pyspark import SparkConf, SparkContext
# 创建SparkConf对象
conf = SparkConf()
conf.setMaster("local[*]") # 本地
conf.setAppName("test_spark_app")
# 也可使用链式调用
# conf = SparkConf.setMaster().setMaster("local[*]").setAppName("test_spark_app")

# 基于SparkConf类对象创建SparkContext对象
sc = SparkContext(conf=conf)

print('spark版本：', sc.version)  # spark版本： 3.3.2

# 停止
sc.stop()


